//package baiguoyuan.kafka.streams;
//
//import org.apache.kafka.common.serialization.Serdes;
//import org.apache.kafka.streams.KafkaStreams;
//import org.apache.kafka.streams.StreamsConfig;
//import org.apache.kafka.streams.kstream.KStreamBuilder;
//
//import java.util.HashMap;
//import java.util.Map;
//
//        public class StreamApi {
//            public static void main(String[] args) {
//                Map<String, Object> props = new HashMap<>();
//                props.put(StreamsConfig.APPLICATION_ID_CONFIG, "my-stream-processing-application");
//                props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.16.150:9092");
//                props.put(StreamsConfig.KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass());
//                props.put(StreamsConfig.VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass());
//                StreamsConfig config = new StreamsConfig(props);
//
//                KStreamBuilder builder = new KStreamBuilder();
//                builder.stream("t1").mapValues(value -> {
//                    Integer i = Integer.parseInt((String) value);
//                    return String.valueOf(i * i);
//                }).to("t2");
//
//        KafkaStreams streams = new KafkaStreams(builder, config);
//        streams.start();
//    }
//
//}